8923feb665cd9e6ce01b8365c17987a5c26fcf7d,src/test/java/net/jodah/lyra/internal/ChannelRecoveryTest.java,ChannelRecoveryTest,mockRecovery,#Exception#,84
Before Change
mockConsumer(2, 5);
mockConsumer(2, 6);
when(mockChannel(2).delegate.basicConsume(eq("test-queue"), eq(mockConsumer(2, 5)))).thenAnswer(
failNTimes(3, e, "test-tag"));
}
}
After Change
failNTimes(2, e, null, mockChannel(2).channelHandler));
when(
mockChannel(2).delegate.basicConsume(eq("test-queue"),
argThat(matcherFor(mockConsumer(2, 5))))).thenAnswer(
failNTimes(3, e, "test-tag", mockChannel(2).channelHandler));
}
}